//package _rxjava2;
//
//import io.reactivex.Emitter;
//import io.reactivex.disposables.Disposable;
//import io.reactivex.functions.Cancellable;
//
///**
// * @author huangya
// * @date 2022/7/8
// */
//public interface FlowableEmitter extends Emitter {
//
//    void setDisposable(Disposable s);
//
//    void setCancellable(Cancellable c);
//
//    /**
//
//     * The current outstanding request amount.
//
//     *
//
//     This method is thread-safe.
//
//     * @return the current outstanding request amount
//
//     */
//
//    long requested(); // 获取到当前请求事件的数量
//
//    boolean isCancelled();
//
//    FlowableEmitter serialize();
//
//}